package com.hadoop.sxtmr;

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;

public class HotReducer extends Reducer<KeyPair, Text, KeyPair, Text>{

	@Override
	protected void reduce(KeyPair key, Iterable<Text> values, Reducer<KeyPair, Text, KeyPair, Text>.Context context)
			throws IOException, InterruptedException {
		for (Text v : values) {
			context.write(key, v);
		}
	}
	

}
